#include "consumer_thread.hpp"
#include <iostream>
#include "pool.hpp"
using std::bind;

namespace rocket 
{
consumer_thread::consumer_thread(pool *p) 
:_pool(p)
{
    _f=bind(&consumer_thread::execute,this);
}
void consumer_thread::execute()
{
    _pool->take_task();
}


}

